package demo.dag;

import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.streaming.api.operators.ChainingStrategy;

abstract class PhysicalTransformationDemo<T> extends TransformationDemo<T> {


    public PhysicalTransformationDemo(String name, TypeInformation<T> outputType, int parallelism) {
        super(name, outputType, parallelism);
    }

    public abstract void setChainingStrategy(ChainingStrategy strategy);
}
